package com.ydl.learning.flink.demo.pipeline.impl

import com.ydl.learning.flink.demo.pipeline.{BaseProcedureImpl, PipelineData, Process}
import org.apache.flink.streaming.api.scala.{DataStream, _}

/**
 *
 *
 * @author ydl
 * @since 2022/1/7
 */
class Process2Impl extends Process[PipelineData] with BaseProcedureImpl {


  override def run: DataStream[PipelineData] = {
    this.dataStream.map(data => {
      data.setData(data.getData[String].split(" "))
      data
    }).name("split space")
  }
}
